//引入exress模块
const express = require('express');
//引入连接池模块
const pool = require('../pool.js');
//创建路由器对象
const r = express.Router();


//1.上传作品
r.post("/uploadWorks",(req,res)=>{ //之后这个sql语句还要加传入的用户id    works.wuid
	var obj=req.body;
    // var datetime = new Date().toLocaleDateString();  //这个是在前端发送请求时写的
	var sql="insert into works (wdes,wdatetime,wpic,wuid) values(?,?,?,?)"; 
	console.log(obj);
	pool.query(sql,[obj.wdes,obj.wdatetime,obj.wpic,obj.wuid],(err,result)=>{
		if(err) throw err;
		if(result.affectedRows>0){
			res.send("1");
		}else{
			res.send("0");
		}
	});
});

//2.获取上传的作品   —————— 获取到的是0时区日期+时间
r.get("/getWorks",(req,res)=>{  
	var _wuid=req.query.wuid;
	var sql="select userInf.uname,userInf.headimg,works.wdes,works.wdatetime,works.wpic from userInf,works where works.wuid=userInf.uid and works.wuid=? ";
	pool.query(sql,[_wuid],(err,result)=>{
		if(err) throw err;
		console.log(result);  //数组
		res.send({ message: 'ok', code: 200, result: result}); //字符串
	});
});

//3. 修改作品
r.put("/updateWorks",(req,res)=>{
	var obj=req.body;
	console.log(obj);
	var sql="update works set wdes=?,wdatetime=?,wpic=? where wid=?";   
	pool.query(sql,[obj.wdes,obj.wdatetime,obj.wpic,obj.wid],(err,result)=>{
		if(err) throw err;
		if(result.affectedRows>0){
			res.send("1");
		}else{
			res.send("0");
		}
	});
});

// 4. 删除作品  
r.delete("/deleteWorks",(req,res)=>{
	var _wid=req.query.wid;
	var sql="delete from works where wid=?";
	pool.query(sql,[_wid],(err,result)=>{
		if(err) throw err;
		if(result.affectedRows>0){
			res.send("1");
		}else{
			res.send("0");
		}
	});
});


//5.获取关注列表作品

//6.添加关注

//7.删除关注





//导出路由器对象
module.exports=r;